package nats

import (
	"fmt"
	"github.com/nats-io/nats.go"
	"purchase-mall/conf"
)

var (
	client *nats.Conn
)

// Init 初始化Nats连接
func Init(cfg *conf.NatsConfig) (err error) {
	fmt.Printf("NatsSQL Switch %v\n", cfg.Switch)
	if cfg.Switch == false {
		return nil
	}

	dsn := fmt.Sprintf("%s:%d", cfg.Host, cfg.Port)
	client, err = nats.Connect(dsn)

	if err != nil {
		return err
	}
	return nil
}
